bac7f79af721874e8d36a01471e0b0362c54e442,modules/mesos/src/main/java/org/apache/ignite/mesos/IgniteScheduler.java,IgniteScheduler,statusUpdate,#SchedulerDriver#Protos.TaskStatus#,291

Before Change


    @Override public void statusUpdate(SchedulerDriver schedulerDriver, Protos.TaskStatus taskStatus) {
        final String taskId = taskStatus.getTaskId().getValue();

        log.info("Received update event task: {} is in state: {}", taskId, taskStatus.getState());

        if (taskStatus.getState().equals(Protos.TaskState.TASK_FAILED)
            || taskStatus.getState().equals(Protos.TaskState.TASK_ERROR)

After Change


    @Override public synchronized void statusUpdate(SchedulerDriver schedulerDriver, Protos.TaskStatus taskStatus) {
        final String taskId = taskStatus.getTaskId().getValue();

        log.log(Level.INFO, "Received update event task: {0} is in state: {1}",
            new Object[]{taskId, taskStatus.getState()});

        if (taskStatus.getState().equals(Protos.TaskState.TASK_FAILED)
            || taskStatus.getState().equals(Protos.TaskState.TASK_ERROR)